package com.zst.amqp.event;

/**
 * 用于标记消息确认回调的接口
 */
@FunctionalInterface
public interface PublisherConfirmCallback {
    /**
     * 消息生产者确认回调方法
     * @param correlationId
     * @param ack
     */
    void confirmCallback(String correlationId, boolean ack);
}
